//package lzzsrj.union.message.test;
//
//import org.springframework.stereotype.Component;
//
//@Component
//public class RedisMQConsumer {
//    @RedisMQListener(queue = "test-1", interval = 2000, quantity = 2)
//    public void redisMQ(RedisMQMessage redisMQMessage) {
//        System.out.println(redisMQMessage.getQueue() + "队列收到消息：" + redisMQMessage);
//    }
//}